package com.jxb.producer;

import com.jxb.RemotingService;
import com.jxb.netty.NettyRemotingClient;
import com.jxb.netty.RemotingClient;

public class Producer {

    private static RemotingService remotingService = new RemotingClient();

    public static void main(String[] args) throws InterruptedException {
        //启动客户端
        remotingService.contectBroker("127.0.0.1", 10911,"producer client");
        remotingService.sendMessage("127.0.0.1", 10911,"焦雄安伯");
    }

}
